package com.ververica.cdc.guass.sink.jdbc.core.database.catalog;

import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.table.catalog.ObjectPath;
import org.apache.flink.table.types.DataType;

import java.sql.ResultSetMetaData;
import java.sql.SQLException;

/** Separate the jdbc meta-information type to flink table type into the interface. */
@PublicEvolving
public interface JdbcCatalogTypeMapper {

    DataType mapping(ObjectPath tablePath, ResultSetMetaData metadata, int colIndex)
            throws SQLException;
}
